b75cbb99bb5ffe8253f94a69e420e2bb6c9fdcc8,raft-grpc/src/main/java/org/apache/raft/grpc/server/GRpcLogAppender.java,AppendLogResponseHandler,onError,#Throwable#,216
Before Change
*/
@Override
public void onError(Throwable t) {
LOG.info("{} got error when appending entries to {}, exception: {}",
server.getId(), follower.getPeer().getId(), t);
// clear the pending requests queue and reset the next index of follower
// TODO reuse the requests
AppendEntriesRequestProto request = pendingRequests.peek();
After Change
LOG.info("{} is stopped", GRpcLogAppender.this);
return;
}
LOG.warn("{} got error when appending entries to {}, exception: {}.",
server.getId(), follower.getPeer().getId(), t);
synchronized (this) {
if (Status.fromThrowable(t) == Status.UNKNOWN) {